

# 进程池
from multiprocessing import Pool


def run(str):
    print("当前子进程: "+ str)


if __name__ == '__main__':
    print("父进程开始")

    # Pool默认进程数是 CPU 核心数
    pp = Pool(4)

    for i in range(5):
        pp.apply_async(run, args=("ok" + str(i),))

    # 不再添加进程入池
    pp.close()

    # 等待进程池中的进程 执行完成后, 主线程才继续执行
    pp.join()

    print("父进程结束")